package com.apex.spark.stream;

import com.apex.spark.SparkBaseSource;
import com.apex.spark.SparkEnvironment;
import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;

/**
 * 实时从数据源端获取数据并发送到下游处理
 */
public interface SparkStreamingSource extends SparkBaseSource {
    /**
     *  获取并发送结果集
     * @param environment 上下文环境
     * @return Dataset<Row>
     */
    Dataset<Row> getData(SparkEnvironment environment);
}
